package org
import org.apache.spark.sql.SparkSession
object Yun {
    def main(args:Array[String]): Unit = {
      val spark = SparkSession.builder().master("local[*]").appName("spark").getOrCreate()
      val sc = spark.sparkContext
      val rdd1 = sc.makeRDD(List(1,5,3,7,6),1)
      val rdd2 = sc.parallelize(List(('a',90),('b',77),('c',66),('d',89)))
      val rdd3 = sc.makeRDD(List(1,2,3,4,5),1)
     // rdd1.intersection(rdd3).foreach(println)
     // rdd1.union(rdd3).foreach(println)
     // rdd1.subtract(rdd3).foreach(println)
     // rdd1.zip(rdd3).foreach(println)
      rdd1.cartesian(rdd3).foreach(println)
      rdd1.foreach(println)
      rdd2.collect().foreach(println)

      sc.stop()
    }
}
